package dataflow.example;

import org.apache.log4j.Logger;

public class w2 {
	
	static Logger log = Logger.getLogger(Worker4.class);
	
	private static int num;
	
	public Integer run(Integer p){
		log.info("w2: running");
		log.info("w2: " + num);
		if(num == 10){
			return 2;
		} else {
			return 3;
		}
	}
	
	public void setdata1(Object o){
		num = (Integer)o;
	}
}
